package com.macro.mall.util;//package com.hpe.util;
//
//import com.hpe.exception.BusinessException;
//import com.jcraft.jsch.*;
//import lombok.AllArgsConstructor;
//import lombok.Builder;
//import lombok.Data;
//import lombok.NoArgsConstructor;
//import lombok.extern.slf4j.Slf4j;
//
//import java.io.*;
//import java.util.*;
//
//@Slf4j
//@Data
//@AllArgsConstructor
//@NoArgsConstructor
//@Builder
//public class SftpUtil {
//
//    private String host;
//    private String username;
//    private String password;
//    private int port = 22;
//
//    private ChannelSftp sftp = null;
//    private Session sshSession = null;
//
//    public SftpUtil(String host, String username, String password)
//    {
//        this.host = host;
//        this.username = username;
//        this.password = password;
//    }
//
//    /**
//     * 通过SFTP连接服务器
//     */
//    public void connect() {
//        try {
//            JSch jsch = new JSch();
//            jsch.getSession(username, host, port);
//            sshSession = jsch.getSession(username, host, port);
//            if (log.isInfoEnabled()) {
//                log.info("Session created.");
//            }
//            sshSession.setPassword(password);
//            Properties sshConfig = new Properties();
//            sshConfig.put("StrictHostKeyChecking", "no");
//            sshSession.setConfig(sshConfig);
//            sshSession.connect();
//            if (log.isInfoEnabled()) {
//                log.info("Session connected.");
//            }
//            Channel channel = sshSession.openChannel("sftp");
//            channel.connect();
//            if (log.isInfoEnabled()) {
//                log.info("Opening Channel.");
//            }
//            sftp = (ChannelSftp) channel;
//            if (log.isInfoEnabled()) {
//                log.info("Connected to " + host + ".");
//            }
//        } catch (Exception e) {
//            e.printStackTrace();
//            log.error("" + e);
//        }
//    }
//
//    /**
//     * 关闭连接
//     */
//    public void disconnect() {
//        if (this.sftp != null) {
//            if (this.sftp.isConnected()) {
//                this.sftp.disconnect();
//                if (log.isInfoEnabled()) {
//                    log.info("sftp is closed already");
//                }
//            }
//        }
//        if (this.sshSession != null) {
//            if (this.sshSession.isConnected()) {
//                this.sshSession.disconnect();
//                if (log.isInfoEnabled()) {
//                    log.info("sshSession is closed already");
//                }
//            }
//        }
//    }
//
//    /**
//     * 批量上传文件
//     * @param remotePath：远程保存目录
//     * @param localPath：本地上传目录(以路径符号结束)
//     * @param del：上传后是否删除本地文件
//     * @return
//     */
//    public boolean batchUploadFile(String remotePath, String localPath,
//                                   boolean del) {
//        try
//        {
//            connect();
//            File file = new File(localPath);
//            File[] files = file.listFiles();
//            for (int i = 0; i < files.length; i++)
//            {
//                if (files[i].isFile())
//                {
//                    if (this.uploadFile(remotePath, files[i].getName(),
//                            localPath, files[i].getName())
//                            && del)
//                    {
//                        deleteFile(localPath + files[i].getName());
//                    }
//                }
//            }
//            if (log.isInfoEnabled())
//            {
//                log.info("upload file is success:remotePath=" + remotePath
//                        + " and localPath=" + localPath + ",file size is "
//                        + files.length);
//            }
//            return true;
//        } catch (Exception e) {
//            e.printStackTrace();
//            throw new BusinessException(e.getMessage(),e);
//        } finally {
//            disconnect();
//        }
//
//    }
//
//    /**
//     * 上传单个文件
//     * @param remotePath：远程保存目录
//     * @param remoteFileName：保存文件名
//     * @param localPath：本地上传目录
//     * @param localFileName：上传的文件名
//     * @return
//     */
//    public boolean uploadFile(String remotePath, String remoteFileName,String localPath, String localFileName) {
//        FileInputStream in = null;
//        try
//        {
//            createDir(remotePath);
//            File file = new File(localPath + File.separator + localFileName);
//            in = new FileInputStream(file);
//            sftp.put(in, remoteFileName);
//            return true;
//        } catch (FileNotFoundException e) {
//            e.printStackTrace();
//            throw new BusinessException(e.getMessage(),e);
//        } catch (SftpException e) {
//            e.printStackTrace();
//            throw new BusinessException(e.getMessage(),e);
//        } finally
//        {
//            if (in != null) {
//                try {
//                    in.close();
//                } catch (IOException e) {
//                    log.error(e.getMessage(),e);
//                    e.printStackTrace();
//                }
//            }
//        }
//    }
//
//    /**
//     * 下载单个文件
//     *
//     * @param remotePath：远程下载目录
//     * @param remoteFileName：下载文件名
//     * @param localPath：本地保存目录
//     * @param localFileName：保存文件名
//     * @return
//     */
//    public boolean downloadFile(String remotePath, String remoteFileName, String localPath, String localFileName) throws BusinessException {
//        FileOutputStream fieloutput = null;
//        try {
//            sftp.cd(remotePath);
//            File file = new File(localPath + File.separator + localFileName);
//            mkdirs(localPath + File.separator + localFileName);
//            fieloutput = new FileOutputStream(file);
//            sftp.get(remotePath + File.separator+ remoteFileName, fieloutput);
//            if (log.isInfoEnabled()) {
//                log.info("===DownloadFile:" + remoteFileName + " success from sftp.");
//            }
//            return true;
//        } catch (Exception e) {
//            e.printStackTrace();
//            throw new BusinessException(e.getMessage(),e);
//        } finally {
//            if (null != fieloutput) {
//                try {
//                    fieloutput.close();
//                } catch (IOException e) {
//                    e.printStackTrace();
//                }
//            }
//        }
//    }
//
//
//    /**
//     *获取文件流
//     * @param remotePath
//     * @param fileName
//     * @return
//     * @throws BusinessException
//     */
//    public InputStream downloadFile(String remotePath, String fileName) throws BusinessException {
//        try {
//            connect();
//            sftp.cd(remotePath);
//            return sftp.get(fileName);
//        } catch (SftpException e) {
//            e.printStackTrace();
//            throw new BusinessException(e.getMessage(),e);
//        } finally {
//            if (sftp != null){
//                disconnect();
//            }
//        }
//    }
//
//
//    /**
//     *获取文件流
//     * @param remotePath
//     * @param fileName
//     * @return
//     * @throws BusinessException
//     */
//    public InputStream download(String remotePath, String fileName) throws BusinessException {
//        try {
//            sftp.cd(remotePath);
//            return sftp.get(fileName);
//        } catch (SftpException e) {
//            e.printStackTrace();
//            log.error("文件下载失败:{}",e);
//            throw new BusinessException(e.getMessage(),e);
//        }
//    }
//
//
//    /**
//     * 上传单个文件
//     *
//     * @param remotePath：远程保存目录
//     * @param remoteFileName：保存文件名
//     * @return
//     */
//    public boolean uploadFile(String remotePath, String remoteFileName, InputStream in) throws BusinessException {
//        try {
//            connect();
//            boolean flag = isDirExist(remotePath);
//            if (!flag){
//                log.info("create dir:{}",remotePath);
//                createDir(remotePath);
//            }
//            if (sftp != null){
//                log.info(sftp.getSession().getHost());
//            }
//            log.info("cd :{}",remotePath);
//            sftp.cd(remotePath);
//            log.info("start upload ...:remotePath:{},fileName:{},file input:{}",remotePath,remoteFileName,in);
//            sftp.put(in, remoteFileName);
//            return true;
//        } catch (SftpException e) {
//            e.printStackTrace();
//            throw new BusinessException(e.getMessage(),e);
//        } catch (JSchException e) {
//            log.error("sftp 服务器连接异常");
//            e.printStackTrace();
//        } finally {
//            if (in != null) {
//                try {
//                    in.close();
//                } catch (IOException e) {
//                    log.error("" + e);
//                    e.printStackTrace();
//                }
//            }
//
//            if (sftp != null){
//                log.error("关闭sftp 连接");
//                disconnect();
//            }
//
//        }
//        return false;
//    }
//
//
//    /**
//     * 创建目录
//     *
//     * @param createpath
//     * @return
//     */
//    public boolean createDir(String createpath) {
//        try {
//            if (isDirExist(createpath)) {
//                log.info("create dir:{}",createpath);
//                this.sftp.cd(createpath);
//                return true;
//            }
//            String pathArry[] = createpath.split(File.separator);
//            StringBuffer filePath = new StringBuffer(File.separator);
//            for (String path : pathArry) {
//                if (path.equals("")) {
//                    continue;
//                }
//                filePath.append(path + File.separator);
//                if (isDirExist(filePath.toString())) {
//                    sftp.cd(filePath.toString());
//                } else {
//                    // 建立目录
//                    sftp.mkdir(filePath.toString());
//                    // 进入并设置为当前目录
//                    sftp.cd(filePath.toString());
//                }
//
//            }
//            this.sftp.cd(createpath);
//            return true;
//        } catch (SftpException e) {
//            log.error("" + e);
//            e.printStackTrace();
//        }
//        return false;
//    }
//
//    /**
//     * 判断目录是否存在
//     *
//     * @param directory
//     * @return
//     */
//    public boolean isDirExist(String directory) {
//        boolean isDirExistFlag = false;
//        try {
//            SftpATTRS sftpATTRS = sftp.lstat(directory);
//            isDirExistFlag = true;
//            return sftpATTRS.isDir();
//        } catch (Exception e) {
//            if (e.getMessage().toLowerCase().equals("no such file")) {
//                isDirExistFlag = false;
//            }
//        }
//        return isDirExistFlag;
//    }
//
//    /**
//     * 如果目录不存在就创建目录
//     *
//     * @param path
//     */
//    public void mkdirs(String path) {
//        File f = new File(path);
//
//        String fs = f.getParent();
//
//        f = new File(fs);
//
//        if (!f.exists()) {
//            f.mkdirs();
//        }
//    }
//
//    /**
//     * 列出目录下的文件
//     *
//     * @param directory：要列出的目录
//     * @return
//     * @throws SftpException
//     */
//    public Vector listFiles(String directory) throws SftpException {
//        return sftp.ls(directory);
//    }
//
//
//    /**
//     * 文件是否存在
//     * @param fileName
//     * @param directory
//     * @return
//     */
//    public boolean fileIsExist(String fileName,String directory){
//        try{
//            List<String> fileNameList = new ArrayList<>();
//            connect();
//            Vector files = sftp.ls(directory);
//            Iterator it = files.iterator();
//            while(it.hasNext()) {
//                String names = ((ChannelSftp.LsEntry) it.next()).getFilename();
//                if (".".equals(names) || "..".equals(names)) {
//                    continue;
//                }
//                fileNameList.add(names);
//            }
//            return fileNameList.contains(fileName);
//        }catch (SftpException e){
//            e.printStackTrace();
//        } finally {
//            if (sftp != null){
//                disconnect();
//            }
//        }
//        return false;
//    }
//
//    /**
//     * 删除本地文件
//     * @param filePath
//     * @return
//     */
//    public boolean deleteFile(String filePath)
//    {
//        File file = new File(filePath);
//        if (!file.exists())
//        {
//            return false;
//        }
//
//        if (!file.isFile())
//        {
//            return false;
//        }
//        boolean rs = file.delete();
//        if (rs && log.isInfoEnabled())
//        {
//            log.info("delete file success from local.");
//        }
//        return rs;
//    }
//
//
//    /**
//     * 文件是否存在
//     * @param fileName
//     * @param directory
//     * @return
//     */
//    public boolean fileIsExists(String fileName,String directory){
//        try{
//            List<String> fileNameList = new ArrayList<>();
//            Vector files = sftp.ls(directory);
//            Iterator it = files.iterator();
//            while(it.hasNext()) {
//                String names = ((ChannelSftp.LsEntry) it.next()).getFilename();
//                if (".".equals(names) || "..".equals(names)) {
//                    continue;
//                }
//                fileNameList.add(names);
//                log.info("directory:{}.contains:{}",directory,names);
//            }
//            return fileNameList.contains(fileName);
//        }catch (SftpException e){
//            e.printStackTrace();
//        }
//        return false;
//    }
//
//    public static void main(String[] args) {
//        SftpUtil sftpUtil = SftpUtil.builder().host("10.34.82.12").port(22).username("root").password("1qaz2wsx").build();
//        sftpUtil.connect();
//            //sftpUtil.uploadFile("/chenwei/chenwei2/chenwei3/","ORDERSTATUSHIS_N_100_20200414_00.xml","/Users/chenwei/IdeaProjects/files","ORDERSTATUSHIS_N_100_20200414_00.xml");
//            //sftpUtil.downloadFile("/chenwei/chenwei2/chenwei3","ORDERSTATUSHIS_N_100_20200414_00.xml1","/Users/chenwei/Downloads/chenwei","ORDERSTATUSHIS_N_100_20200414_00.xml");
//            try {
////                Long fileLineNumber = sftpUtil.getFileLineNumber("/outgoing/upms3", "vc_456321_20200817.txt");
////                System.out.println(fileLineNumber);
//                //int fileLineNumber = sftpUtil.getFileLineNumber("/outgoing/upms3", "vc_456321_20200817.txt");
//                //System.out.println(fileLineNumber);
//            } catch (Exception e) {
//                e.printStackTrace();
//            }
//        sftpUtil.disconnect();
//        //sftpUtil.batchUploadFile("/chenwei/chenwei2/chenwei3/","/Users/chenwei/IdeaProjects/files/",false);
//
//    }
//
//}
